package xyz.xiaoshengfu.xrpc.consumer;

import redis.clients.jedis.JedisPubSub;

/**
 * <p>Title: XRpcConsumerRedisSubscribe</p>
 * <p>Description: 服务消费者接收注册中心发来的服务提供者上线信息</p>
 * @author xiaoshengfu(2439323118@qq.com)
 * @date 2020年3月24日
 */
public class XRpcConsumerRedisSubscribe extends JedisPubSub {

	/**
	 * 取得订阅的消息后的处理 
	 */
	@Override
	public void onMessage(String channel, String message) {
		XRpcConsumerSubscribeClient.onSubscribeMessage(channel, message);
	}

	/**
	 * 初始化订阅时候的处理 
	 */
	@Override
	public void onSubscribe(String channel, int subscribedChannels) {
	}

	/**
	 * 取消订阅时候的处理 
	 */
	@Override
	public void onUnsubscribe(String channel, int subscribedChannels) {

	}
}